package com.eshipenet.shipnet.edpersistor

import org.apache.flink.streaming.api.functions.sink.SinkFunction
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.influxdb.dto.Point

object EquipmentDataSinkProvider {

  def create(env: StreamExecutionEnvironment): SinkFunction[InfluxDBPoint] = {
    val config = InfluxDBConfig(url = "http://192.168.1.17:8186")
    new FlinkInfluxDBSink(config)
  }

}
